package com.unism.uniMeterage.meterage.stream.version1_0;
/**
 * @author liuc
 * 消费者作模式接口
 */
public interface Consumer {

    /**
     * 初始化生产者
     */
    public void  init();

    /**
     * 消费者生产数据
     * @return 生产的数据
     */
    public Object  nextData();

    /**
     * 后续数据处理失败
     */
    public void  fail();

    /**
     * 后续数据处理成功
     */
    public void  success();
}
